/*
 * 文件名：RealStreamUnitDao.java
 * 版权：亚信联创版权所有
 * 描述：TODO
 * 修改人：qiuyc
 * 修改时间：2014年11月2日
 * 修改内容：TODO
 */
package com.ailk.bigdata.etl.realstream.server.dao;

import java.util.List;

import com.ailk.bigdata.etl.realstream.server.model.KafkaInfo;
import com.ailk.bigdata.etl.realstream.server.model.RealStreamUnit;

/**
 * @description TODO
 * @author [qiuyc]
 * @version [版本号,2014年11月2日]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public interface RealStreamUnitDao
{
	public List<RealStreamUnit> getAllUnit();

	public List<RealStreamUnit> getAllStreamUnit();

	/**
	 * 
	 * @description 获取所有的计算编码
	 * @return
	 */
	public List<RealStreamUnit> getAllCalcUnitCode();

	public RealStreamUnit getUnitByUnitCode(long onlyUnitCode);

	public RealStreamUnit getUnitAllByUnitCode(long onlyUnitCode);

	/**
	 * 
	 * @description 获取所有被动单元信息
	 * @return
	 */
	public List<RealStreamUnit> getAllPassivUnit();

	/**
	 * 
	 * @description 获取所有主动单元信息
	 * @return
	 */
	public List<RealStreamUnit> getAllInitiativeUnit();

	/**
	 * @description 获取需要发送到kafka的消息
	 * @return
	 */
	public List<RealStreamUnit> getALLKafkaSendUnit();

	public KafkaInfo getKafkaInfo(String kafkaId);

}
